f5aeaba4a24fdeafc5ae0f4e69336902346c6bf1,src/main/java/io/vertx/ext/stomp/DefaultNackHandler.java,DefaultNackHandler,handle,#ServerFrame#,20
Before Change
sf.connection().close();
return;
} else {
transaction.addFrameToTransaction(sf.frame());
Frames.handleReceipt(sf.frame(), sf.connection());
// Nothing else in transactions.
return;
After Change
connection.close();
return;
} else {
if (!transaction.addFrameToTransaction(sf.frame())) {
// Frame not added to transaction
Frame errorFrame = Frames.createErrorFrame("Frame not added to transaction",
Headers.create(Frame.ID, id, Frame.TRANSACTION, txId),
"Message delivery failed - the frame cannot be added to the transaction - the number of allowed thread " +
"may have been reached");
connection.handler().unregisterTransactionsFromConnection(connection);
connection.write(errorFrame);
connection.close();
return;
}
Frames.handleReceipt(sf.frame(), connection);
// Nothing else in transactions.
return;